package com.iwhalecloud.uncc.model;

import java.io.Serializable;

public class MqConsumerConfig implements Serializable {

	private String topic;
	private String tag;
	private String consumerName;
	private String consumeFromWhere;
	private Integer consumeThreadMin;
	private Integer consumeThreadMax;
	private String messageModel;
	private Integer consumeBatchSize;

	public String getTopic() {
		return topic;
	}

	public void setTopic(String topic) {
		this.topic = topic;
	}

	public String getTag() {
		return tag;
	}

	public void setTag(String tag) {
		this.tag = tag;
	}

	public String getConsumerName() {
		return consumerName;
	}

	public void setConsumerName(String consumerName) {
		this.consumerName = consumerName;
	}

	public String getConsumeFromWhere() {
		return consumeFromWhere;
	}

	public void setConsumeFromWhere(String consumeFromWhere) {
		this.consumeFromWhere = consumeFromWhere;
	}

	public Integer getConsumeThreadMin() {
		return consumeThreadMin;
	}

	public void setConsumeThreadMin(Integer consumeThreadMin) {
		this.consumeThreadMin = consumeThreadMin;
	}

	public Integer getConsumeThreadMax() {
		return consumeThreadMax;
	}

	public void setConsumeThreadMax(Integer consumeThreadMax) {
		this.consumeThreadMax = consumeThreadMax;
	}

	public String getMessageModel() {
		return messageModel;
	}

	public void setMessageModel(String messageModel) {
		this.messageModel = messageModel;
	}

	public Integer getConsumeBatchSize() {
		if (consumeBatchSize == null) {
			consumeBatchSize = 1;
		}
		return consumeBatchSize;
	}

	public void setConsumeBatchSize(Integer consumeBatchSize) {
		this.consumeBatchSize = consumeBatchSize;
	}

}
